google.golang.org/grpc.csAttempt.transportStream (field)

35 uses

	google.golang.org/grpc (current package)
		rpc_util.go#L226: 	*o.HeaderAddr, _ = attempt.transportStream.Header()
		rpc_util.go#L248: 	*o.TrailerAddr = attempt.transportStream.Trailer()
		rpc_util.go#L270: 	if x, ok := peer.FromContext(attempt.transportStream.Context()); ok {
		stream.go#L530: 	a.transportStream = s
		stream.go#L601: 	transportStream *transport.ClientStream
		stream.go#L654: 	if a.transportStream == nil && a.allowTransparentRetry {
		stream.go#L659: 	if a.transportStream != nil {
		stream.go#L660: 		<-a.transportStream.Done()
		stream.go#L661: 		unprocessed = a.transportStream.Unprocessed()
		stream.go#L673: 	if a.transportStream != nil {
		stream.go#L674: 		if !a.transportStream.TrailersOnly() {
		stream.go#L680: 		sps := a.transportStream.Trailer()["grpc-retry-pushback-ms"]
		stream.go#L697: 	if a.transportStream != nil {
		stream.go#L698: 		code = a.transportStream.Status().Code()
		stream.go#L771: 	if cs.attempt.transportStream != nil {
		stream.go#L772: 		return cs.attempt.transportStream.Context()
		stream.go#L809: 			<-a.transportStream.Done()
		stream.go#L811: 		if err == nil || (err == io.EOF && a.transportStream.Status().Code() == codes.OK) {
		stream.go#L827: 		m, err = a.transportStream.Header()
		stream.go#L871: 	if cs.attempt.transportStream == nil {
		stream.go#L874: 	return cs.attempt.transportStream.Trailer()
		stream.go#L1007: 		a.transportStream.Write(nil, nil, &transport.WriteOptions{Last: true})
		stream.go#L1048: 		if cs.attempt.transportStream != nil {
		stream.go#L1102: 	if err := a.transportStream.Write(hdr, payld, &transport.WriteOptions{Last: !cs.desc.ClientStreams}); err != nil {
		stream.go#L1128: 		if ct := a.transportStream.RecvCompress(); ct != "" && ct != encoding.Identity {
		stream.go#L1142: 	if err := recv(a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, payInfo, a.decompressorV1, false); err != nil {
		stream.go#L1144: 			if statusErr := a.transportStream.Status().Err(); statusErr != nil {
		stream.go#L1175: 	if err := recv(a.parser, cs.codec, a.transportStream, a.decompressorV0, m, *cs.callInfo.maxReceiveMessageSize, nil, a.decompressorV1, false); err == io.EOF {
		stream.go#L1176: 		return a.transportStream.Status().Err() // non-server streaming Recv returns nil on success
		stream.go#L1195: 	if a.transportStream != nil {
		stream.go#L1196: 		a.transportStream.Close(err)
		stream.go#L1197: 		tr = a.transportStream.Trailer()
		stream.go#L1202: 		if a.transportStream != nil {
		stream.go#L1203: 			br = a.transportStream.BytesReceived()
		stream.go#L1208: 			BytesSent:     a.transportStream != nil,

The pages are generated with Golds v0.7.6. (GOOS=linux GOARCH=amd64)